package org.example.other.adapter;

import org.example.flink.stream.condition.ConditionPattern;
import org.example.other.AdapterCallBack;

public class SignPatternAdapter implements Runnable{
    private String mappingKey;//db.table.col
    private String tagKey;
    private Object data;
    private ConditionPattern condition;
    private AdapterCallBack callBack;
    @Override
    public void run() {
        Object tagValue = null;
        if(condition==null) {
            //直接写入
            tagValue = data;
        }else {
            tagValue = condition.transtion(data);
        }
        callBack.call(tagValue);
    }
}
